package com.example.pong.mq;

/**
 * @author Jim
 * @create 2025/1/13
 */
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Service;

@Service
@RocketMQMessageListener(topic = "log-topic", consumerGroup = "pong-log-consumer")
@Slf4j
public class LogConsumer implements RocketMQListener<String> {

    @Override
    public void onMessage(String logMessage) {
        // 这里是从 RocketMQ 消费到日志消息
        // 将日志消息写入文件或其他存储
//        System.out.println("Received log: " + logMessage);  // 可以替换为写入日志文件的操作

        // 在实际应用中，您可以使用日志框架（如 Logback）将日志写入文件
        // logger.info(logMessage);
        log.info("Received log: " + logMessage);
    }
}
